6f56a9fcf1b99ae4a7f6c68eff17263ba9adb4bb,WordCountApp/src/WordCountApp/WordCountFlow.java,WordCountFlow,configure,#,31
Before Change
.setName("WordCountFlow")
.setDescription("Example Word Count Flow")
.withFlowlets()
.add(new WordSplitterFlowlet()).apply()
.add(new WordCounterFlowlet()).apply()
.add(new WordAssociaterFlowlet()).apply()
.add(new UniqueCounterFlowlet()).apply()
.connect()
.from(new Stream("wordStream")).to(new WordSplitterFlowlet())
.from(new WordSplitterFlowlet()).to(new WordCounterFlowlet())
.from(new WordSplitterFlowlet()).to(new WordAssociaterFlowlet())
.from(new WordCounterFlowlet()).to(new UniqueCounterFlowlet())
.build();
}
}
After Change
.setName("WordCountFlow")
.setDescription("Example Word Count Flow")
.withFlowlets()
.add("wordSplitter", new WordSplitterFlowlet())
.add("wordCounter", new WordCounterFlowlet())
.add("wordAssociater", new WordAssociaterFlowlet())
.add("uniqueCounter", new UniqueCounterFlowlet())
.connect()
.fromStream("wordStream").to("wordSplitter")
.from("wordSplitter").to("wordCounter")
.from("wordSplitter").to("wordAssociater")
.from("wordCounter").to("uniqueCounter")
.build();